使用Mybatis对数据库进行单表操作代码实现示例

2022-05-18 20:36| 来源: 网络整理| 查看: 265

本篇文章小编给大家分享一下使用Mybatis对数据库进行单表操作代码实现示例，文章代码介绍的很详细，小编觉得挺不错的，现在分享给大家供大家参考，有需要的小伙伴们可以来看看。

简介

使用的环境如下：

JDK版本：1.8

编译器：IDEA2019

JDBC版本：8.0.18

mybatis版本：3.5.3

配置文件

首先需要有两个配置文件，一个是configuration.xml文件，配置的是连接数据库的环境以及对于mapper.xml文件的映射，还有另一个文件就是mapper.xml，这个文件主要是用来写sql语句的

configuration.xml文件

mapper.xml文件

INSERT ATM VALUES(#{account}, #{password}, #{balance}) update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account}; DELETE FROM ATM WHERE account=#{account};

具体操作

具体操作看如下代码，对代码都进行了一定的注释，并结合mapper.xml文件一起看

public class UserDao { //增加一条记录，user对象是我创建的实体类 //mapper.xml文件的sql语句如下： //update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account}; //#{key}中的key要和实体类user的属性名一致 //如果传递的是基本数据类型或者String，且#{key}只有一个，那么名字可以不一致 //如果传入的是map集合，#{key}中的key要和map集合里的key一致 public void insert(User user){ //MYBATIS操作流程 //获取工厂Builder对象 SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder(); //获取configuration.xml配置文件的输入流 InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml"); //builder根据is获取SqlSessionFactory工厂对象 SqlSessionFactory factory = builder.build(is); //获取SqlSession对象 SqlSession sqlSession = factory.openSession(); //执行sql语句操作 //insert是在mapper.xml下，insert标签的id名 //user是我要插入的数据（动态操作），替换掉sql语句的#{} sqlSession.insert("insert", user); sqlSession.commit(); } //改：修改记录，user是要修改的数据 //mapper.xml文件的sql语句如下： //update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account}; public void update(User user){ //MYBATIS操作流程 //获取工厂Builder对象 SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder(); //获取configuration.xml配置文件的输入流 InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml"); //builder根据is获取SqlSessionFactory工厂对象 SqlSessionFactory factory = builder.build(is); //获取SqlSession对象 SqlSession sqlSession = factory.openSession(true); //执行sql语句操作 sqlSession.update("update",user); } //删除：根据account删除 //mapper.xml的sql语句如下： // DELETE FROM ATM WHERE account=#{account}; public void delete(String account){ //MYBATIS操作流程 //获取工厂Builder对象 SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder(); //获取configuration.xml配置文件的输入流 InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml"); //builder根据is获取SqlSessionFactory工厂对象 SqlSessionFactory factory = builder.build(is); //获取SqlSession对象 SqlSession sqlSession = factory.openSession(true); //执行sql语句操作 sqlSession.update("delete",account); } //===============================查询==================================== //查询：查找记录总条数以及balance的最大值 //sql语句如下：select count(*),max(balance) from atm; //select标签上的resultType表示的是返回值，指的是一条记录的类型，最后包裹成list集合 //我这里用的hashMap public List> gettotal(){ InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml"); SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is); SqlSession sqlSession = factory.openSession(true); return sqlSession.selectList("gettotal"); } //查询：获取总记录数 //sql语句： SELECT COUNT(*) FROM atm; //resultType类型：integer public Integer getTotalCount(){ InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml"); SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is); SqlSession sqlSession = factory.openSession(true); return sqlSession.selectOne("getTotalCount"); } //查询：获取表格的所有记录 //sql语句：SELECT *FROM atm; //resultType类型：domain.User （如果是自己写的实体类，需要类名的具体路径，除非做了配置） public List selectAll(){ InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml"); SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is); SqlSession sqlSession = factory.openSession(true); return sqlSession.selectList("selectAll"); } //查询：查询所有该表所有记录，并根据flag列进行order排序 //flag不确定，order可能是升序也可能是降序(由调用这个方法的用户决定) //sql语句： SELECT *FROM atm order by ${flag} ${order}; //这里用的是${}而不是#{} //#{}和${}的区别： //#{}:当我们的动态参数是用作条件的时候我们用这个，比如说account=#{key} //${}：当我们的动态参数表示的是一个普通字符串，比如说表名、列名或者关键字我们用这个 //resultType：domain.User(domain包下的User类） public List selectAllByAcc(String flag, String order){ InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml"); SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is); SqlSession sqlSession = factory.openSession(true); Map map = new HashMap(); map.put("flag", flag); map.put("order", order); return sqlSession.selectList("selectAllByAcc", map); } }

关于单表操作的底层原理

这里简单提一下关于增删改查操作的底层原理，以查询操作为例，查询操作和增删改操作的主要区别在于sql语句的不同以及查询操作有返回值，所以底层还需要处理返回值

例如：sqlSession.selectOne(sql,obj)

1）首先，底层需要根据configuration.xml，找到mysql的驱动类driver，加载驱动

2）根据configuration.xml文件，找到连接MySQL数据库的url,user,password，获取连接Connection

3）参考configuration.xml配置文件，找到mapper.xml文件，从而找到sql语句，创建状态参数PreparedStatement

4）解析sql语句，把#{key}或者${key}转换成?的形式，并记录key的名字，根据传递过来的obj匹配key，如果传递过来的是domain实体对象，通过反射获取domain实体中的所有属性，根据属性名字去匹配key，然后调用状态参数的setObject方法对?进行复制（其他类型的对象也基本如此）

5）执行SQL操作，获取结果集

6）分析ResultType属性，获取返回值类型，通过反射创建对象，遍历结果集，将结果集包装成返回值类型的对象

【本文地址】

公司简介

联系我们